package com.itstherules.jmsunit.managers;

import javax.jms.JMSException;
import javax.jms.MessageConsumer;
import javax.jms.Queue;
import javax.jms.QueueBrowser;
import javax.jms.QueueReceiver;
import javax.jms.QueueSender;
import javax.jms.TextMessage;

public interface QueueManager {
	
	public void close() throws JMSException;

	public Queue createQueue(String queue) throws JMSException;

	public QueueSender getQueueSender(String queue) throws JMSException;

	public QueueReceiver getQueueReceiver(String queue) throws JMSException;
	
	public MessageConsumer getMessageConsumerWithMessageID(String queue, String messageId) throws JMSException;

	public TextMessage createTextMessage(String message) throws JMSException;

	public QueueBrowser getQueueBrowser(String queue) throws JMSException;

	public TextMessage getTextMessage(String message);

}